package com.xiangyun.xyojbackendjudgeservice;

import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
import lombok.extern.slf4j.Slf4j;


@Slf4j
public class InitRabbitMq {

    public static void initMq(){
            try {
                ConnectionFactory factory = new ConnectionFactory();
                factory.setHost("localhost");
                Connection connection = factory.newConnection();
                Channel channel = connection.createChannel();
                String EXCHANGE_NAME = "code_exchange";
                channel.exchangeDeclare(EXCHANGE_NAME, "direct");

                // 创建队列，随机分配一个队列名称
                String queueName = "code_queue";
                channel.queueDeclare(queueName, true, false, false, null);
                channel.queueBind(queueName, EXCHANGE_NAME, "my_routingKey");
            } catch (Exception e) {
                log.error("消息队列创建失败");
            }
    }
}
